package org.wj.arithmetic

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}

object Filter extends App {


  val conf = new SparkConf().setAppName(this.getClass.getName).setMaster("local")

  val sc = new SparkContext(conf)

  private val rdd: RDD[Int] = sc.parallelize(1 to 100)

  rdd.filter(_ > 10).foreach(println(_))

}
